// 引入mysql
const mysql = require('mysql');
const { DATABASE_NAME, DATABASE_USERNAME, DATABASE_PASSWORD, DATABASE_PORT, DATABASE_HOST,TABLE_HISTORY_NAME } = require('../constants/constants')
const createHistoryTable = require('./HistoryModel')

console.log(`数据库开始创建链接`);

// 创建连接
const connection = mysql.createConnection({
    host: DATABASE_HOST, // 数据库地址
    user: DATABASE_USERNAME, // 用户名
    password: DATABASE_PASSWORD, // 密码
    database: DATABASE_NAME
})
console.log(`数据库开始连接数据库--->${connection}`);
// 连接数据库
connection.connect(err => {
    if (err) {
        console.error('连接数据库发生错误： ' + err.stack);
        return;
    }
    console.log(`数据库开始创建DB`);
    // 检查并创建数据库
    // 查询ffmepg数据库是否存在，如果不存在则创建
    connection.query(`CREATE DATABASE IF NOT EXISTS ${DATABASE_NAME}`, (err, result) => {
        if (err) {
            console.error('创建数据库失败： ' + err.message);
            return;
        }
        console.log(`数据库${DATABASE_NAME}已存在或已创建`);
        createHistoryTable(connection)
    });
})
console.log(`数据库链接结束`);
module.exports = connection